package server

import (
	"fmt"
	"github.com/nats-io/nats.go"
	"gitee.com/ichub/gofactroy/nats/msg2nets"
)

var NatsMng msg2nats.NatsManager

const subj = "UserRegMsg2Cms"

func init() {
	NatsMng.Ini()
	NatsMng.Register(subj, regReplyHandler)

}

func Subscribes(nc *nats.Conn) {

	NatsMng.Nc = nc
	for k, _ := range NatsMng.Mapnats {
		err := NatsMng.Subscribe(k)
		if err != nil {
			fmt.Println(err)

		}
	}

}
func SubscribeOne(nc *nats.Conn, Topic string) {

	NatsMng.Nc = nc
	err := NatsMng.Subscribe(Topic)
	if err != nil {
		fmt.Println(err)
		return
	}

}
